package org.databandtech.mockmq;

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class KafkaUtils {
	private static Logger logger = LoggerFactory.getLogger(KafkaUtils.class);

	public static void send(KafkaProducer<String, String> kafkaProducer, String topic, String strJson) {

		logger.info(strJson);
		
		//ProducerRecord<String, String> pr = new ProducerRecord<String, String>(topic, strJson);
		//kafkaProducer.send(pr);
		//System.out.println(strJson);
	}

}
